package org.jetlinks.pro.messaging.kafka.command;

import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.Setter;
import org.jetlinks.pro.datasource.Command;
import org.jetlinks.pro.messaging.kafka.KafkaConsumer;
import org.jetlinks.pro.messaging.kafka.KafkaProducer;
import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
import reactor.core.publisher.Mono;

@Getter
@Setter
@AllArgsConstructor
public class CreateProducer implements Command<Mono<KafkaProducer>> {

    private KafkaProperties properties;

}
